package com.huitone.smspfm.core.waterpipe.trunk.impl;

import java.util.List;

import com.huitone.smspfm.logger.ExtLogger;

import com.huitone.smspfm.core.waterpipe.trunk.AbstractMainPipe;
import com.huitone.smspfm.redis.model.SmsEntity;

public class SimpleMainPipe extends AbstractMainPipe {
	
	private ExtLogger logger = ExtLogger.create(SimpleMainPipe.class);

	@Override
	protected void lastProcess(List<SmsEntity> entities) {
		
		if (entities != null && entities.size() > 0) {
			for (SmsEntity entity:entities) {
				logger.warn("[序列号:用户号码][" + entity.getSequence() + ":" + entity.getUser() + "]没有匹配到优先级队列,处理流程结束。");
			}
		}
	}

	@Override
	protected void lastProcess(SmsEntity entity) {
		if (entity != null) {
			logger.warn("[序列号:用户号码][" + entity.getSequence() + ":" + entity.getUser() + "]没有匹配到优先级队列,处理流程结束。");
		}
	}

}
